# 主程序
from celery import Celery
# 创建celery实例对象
app = Celery('luffy')

    #1.如果celery需要在任务中调用其它框架的内部对象，则需要进行相应的框架初始化

import os
import django
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'luffyapi.settings.dev')
django.setup()

# 2.加载初始化配置
app.config_from_object('mycelery.config')

# 2.注册异步任务
# 参数必须必须是一个列表，里面的每一个任务都是任务的路径名称
# app.autodiscover_tasks(["任务1","任务2",....])
app.autodiscover_tasks(['mycelery.sms', 'mycelery.cache'])


# 启动Celery的命令
# 强烈建议切换目录到项目的根目录下启动celery!!
# celery -A mycelery.main worker --loglevel=info

# win10下需要采用协程来运行
# pip install eventlet
# celery -A mycelery.main worker -l info -P eventlet

